google.golang.org/grpc.Server.opts (field)
76 uses
google.golang.org/grpc (current package)
server.go#L72: return srv.opts.creds
server.go#L88: return istats.NewMetricsRecorderList(srv.opts.statsHandlers)
server.go#L127: opts serverOptions
server.go#L679: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L696: opts: opts,
server.go#L711: if s.opts.numServerWorkers > 0 {
server.go#L970: rawConn.SetDeadline(time.Now().Add(s.opts.connectionTimeout))
server.go#L998: MaxStreams: s.opts.maxConcurrentStreams,
server.go#L999: ConnectionTimeout: s.opts.connectionTimeout,
server.go#L1000: Credentials: s.opts.creds,
server.go#L1001: InTapHandle: s.opts.inTapHandle,
server.go#L1002: StatsHandlers: s.opts.statsHandlers,
server.go#L1003: KeepaliveParams: s.opts.keepaliveParams,
server.go#L1004: KeepalivePolicy: s.opts.keepalivePolicy,
server.go#L1005: InitialWindowSize: s.opts.initialWindowSize,
server.go#L1006: InitialConnWindowSize: s.opts.initialConnWindowSize,
server.go#L1007: WriteBufferSize: s.opts.writeBufferSize,
server.go#L1008: ReadBufferSize: s.opts.readBufferSize,
server.go#L1009: SharedWriteBuffer: s.opts.sharedWriteBuffer,
server.go#L1011: MaxHeaderListSize: s.opts.maxHeaderListSize,
server.go#L1012: HeaderTableSize: s.opts.headerTableSize,
server.go#L1013: BufferPool: s.opts.bufferPool,
server.go#L1014: StaticWindowSize: s.opts.staticWindowSize,
server.go#L1039: for _, sh := range s.opts.statsHandlers {
server.go#L1049: for _, sh := range s.opts.statsHandlers {
server.go#L1054: streamQuota := newHandlerQuota(s.opts.maxConcurrentStreams)
server.go#L1064: if s.opts.numServerWorkers > 0 {
server.go#L1107: st, err := transport.NewServerHandlerTransport(w, r, s.opts.statsHandlers, s.opts.bufferPool)
server.go#L1178: compData, pf, err := compress(data, cp, comp, s.opts.bufferPool)
server.go#L1197: if payloadLen > s.opts.maxSendMessageSize {
server.go#L1198: return status.Errorf(codes.ResourceExhausted, "grpc: trying to send message larger than max (%d vs. %d)", payloadLen, s.opts.maxSendMessageSize)
server.go#L1202: if len(s.opts.statsHandlers) != 0 {
server.go#L1203: for _, sh := range s.opts.statsHandlers {
server.go#L1215: interceptors := s.opts.chainUnaryInts
server.go#L1216: if s.opts.unaryInt != nil {
server.go#L1217: interceptors = append([]UnaryServerInterceptor{s.opts.unaryInt}, s.opts.chainUnaryInts...)
server.go#L1229: s.opts.unaryInt = chainedInt
server.go#L1248: shs := s.opts.statsHandlers
server.go#L1309: if s.opts.binaryLogger != nil {
server.go#L1310: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1349: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1350: dc = s.opts.dc
server.go#L1364: if s.opts.cp != nil {
server.go#L1365: cp = s.opts.cp
server.go#L1387: d, err := recvAndDecompress(&parser{r: stream, bufferPool: s.opts.bufferPool}, stream, dc, s.opts.maxReceiveMessageSize, payInfo, decomp, true)
server.go#L1431: reply, appErr := md.Handler(info.serviceImpl, ctx, df, s.opts.unaryInt)
server.go#L1546: interceptors := s.opts.chainStreamInts
server.go#L1547: if s.opts.streamInt != nil {
server.go#L1548: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1560: s.opts.streamInt = chainedInt
server.go#L1582: shs := s.opts.statsHandlers
server.go#L1599: p: &parser{r: stream, bufferPool: s.opts.bufferPool},
server.go#L1602: maxReceiveMessageSize: s.opts.maxReceiveMessageSize,
server.go#L1603: maxSendMessageSize: s.opts.maxSendMessageSize,
server.go#L1648: if s.opts.binaryLogger != nil {
server.go#L1649: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1679: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1680: ss.decompressorV0 = s.opts.dc
server.go#L1694: if s.opts.cp != nil {
server.go#L1695: ss.compressorV0 = s.opts.cp
server.go#L1696: ss.sendCompressorName = s.opts.cp.Type()
server.go#L1721: if s.opts.streamInt == nil {
server.go#L1729: appErr = s.opts.streamInt(server, ss, info, sd.Handler)
server.go#L1821: if len(s.opts.statsHandlers) > 0 {
server.go#L1823: for _, sh := range s.opts.statsHandlers {
server.go#L1851: if unknownDesc := s.opts.unknownStreamDesc; unknownDesc != nil {
server.go#L1964: if s.opts.numServerWorkers > 0 {
server.go#L1972: if graceful || s.opts.waitForHandlers {
server.go#L2014: if s.opts.codec != nil {
server.go#L2015: return s.opts.codec